<?php
$dir = dirname(dirname(__FILE__));
include($dir.'/__queue_global.php');
include(SERVER_ROOT_PATH.'/include/config/ml_suggest_config.php');


class ml_mq_suggest_tagInitRedis extends MqClass{
    const QUEUE_NAME = ML_QUEUENAME_SUGGEST_NEWTAG;
    private $oRdsSuggest;
    private $oBizSuggest;
    
    public function __construct($queue)
    {
        $this->oBizSuggest = new ml_biz_suggest_tag();
        
        parent::__construct($queue);
    }    
    
    public function run_job(){
        //接收的数据
        $arr = $this->src_data;
        
        $tag = trim($arr['tag']); 
        $tag_id = $arr['tag_id'];
        
        if (empty($tag) || empty($tag_id)) {
            return ;
        }
        
        $re = $this->oBizSuggest->init_tag_redis($tag, $tag_id);
        
    }
    
    
}

$xblog_obj = new ml_mq_suggest_tagInitRedis(new McQueue(ml_mq_suggest_tagInitRedis::QUEUE_NAME));
$argv[1]   = __FILE__;
$xblog_obj->setArgv($argv[1]);
$xblog_obj->execute();